package cn.ac.iscas.service.transformer;

import cn.ac.iscas.domain.source.FlinkSourceColumn;

import java.util.List;

public class JoinTransformer {
    private final static String ID = "join_trans";

    private final static String JOIN_KEY = "join";
    private final static String LEFT_COLUMN_KEY = "leftColumn";

    private final static String RIGHT_COLUMN_KEY = "rightColumn";




    private String jobId;
    private String componentId;
    private String frontTableName;

    private String currentTableName;
    private List<FlinkSourceColumn> currentColumns;
    private List<FlinkSourceColumn> frontColumns;

    public JoinTransformer(String jobId, String taskId) {
        this.jobId = jobId;
        this.componentId = taskId;
    }

    public JoinTransformer(String jobId, String taskId, String frontTableName, List<FlinkSourceColumn> frontColumns) {
        this.jobId = jobId;
        this.componentId = taskId;
        this.frontTableName = frontTableName;
        this.frontColumns = frontColumns;
        this.currentColumns = frontColumns;
    }




}
